# -*- coding: utf-8 -*-
from datetime import timedelta
from utils.operators.spark_sql_operator import SparkSqlOperator
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor.time_after_08_30 import time_after_08_30


jms_dm__dm_outport_effect_summary_dt_08_30 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dm__dm_outport_effect_summary_dt_08_30",
    filepath='/dw/hive/jms_dm.db/external/dm_outport_effect_summary_dt/dt={{ execution_date | cst_ds }}',
    execution_timeout=timedelta(minutes=30),
    email=['matthew.xiong@jtexpress.com', 'yl_bigdata@yl-scm.com'],
    retries=2,
)
jms_dm__dm_outport_effect_summary_dt_08_30 << time_after_08_30